7583161a1bb680cd641e8e64217945ee228fd93a,src/test/java/uk/sky/cirrus/locking/CassandraLockingMechanismTest.java,CassandraLockingMechanismTest,baseSetup,#,55
Before Change
primingClient.prime(PrimingRequest.queryBuilder()
.withQuery("INSERT INTO locks.locks (name, client) VALUES (?, ?) IF NOT EXISTS")
.withThen(then()
.withColumnTypes(ColumnMetadata.column("client", PrimitiveType.UUID), ColumnMetadata.column("[applied]", PrimitiveType.BOOLEAN))
.withRows(ImmutableMap.of("client", CLIENT, "[applied]", true)))
.build()
);
After Change
primingClient.prime(PrimingRequest.preparedStatementBuilder()
.withQuery("INSERT INTO locks.locks (name, client) VALUES (?, ?) IF NOT EXISTS")
.withThen(then()
.withVariableTypes(PrimitiveType.TEXT, PrimitiveType.UUID)
.withColumnTypes(column("[applied]", PrimitiveType.BOOLEAN))
.withRows(ImmutableMap.of("[applied]", true)))
.build()
);
primingClient.prime(PrimingRequest.preparedStatementBuilder()
.withQuery("DELETE FROM locks.locks WHERE name = ? IF client = ?")
.withThen(then()
.withVariableTypes(PrimitiveType.TEXT, PrimitiveType.UUID)
.withColumnTypes(column("[applied]", PrimitiveType.BOOLEAN))
.withRows(ImmutableMap.of("[applied]", true)))
.build()
);